package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.DataCenterBinderConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * @ClassName DataCenterConsumerBinder
 * @Description TODO
 * @Author mengna.Deng
 * @Date 2021/5/6 15:56
 * @Version 1.0
 */
@Service("dataCenterBinder")
public interface DataCenterConsumerBinder {
    /**
     * 数据预警
     */
    @Input(DataCenterBinderConstant.DATA_WARNING_INPUT)
    SubscribableChannel dataWarningInput();
}
